package com.xisan.practice.rabbitmq.workqueue;

import com.rabbitmq.client.*;
import com.xisan.practice.rabbitmq.utils.RabbitMQUtils;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

/**
 * work模型--每个消费者都平均消费，消费慢的也会逐渐消费，即使其它效率快的也不会多劳多得
 * 方案：每次消费1条、并且手动确认--解决能者多劳
 */
public class Consumer1 {

    public static void main(String[] args) throws IOException, TimeoutException {
        //1.工具类获取连接对象
        Connection connection = RabbitMQUtils.getConnection();
        //2.创建通道
        assert connection != null;
        Channel channel = connection.createChannel();
        //每次消费一条，防止多条分配，处理一般宕机/阻塞导致消息丢失
        channel.basicQos(1);
        //3.通道绑定对象
        channel.queueDeclare("work", false, false, false, null);
        //4.消费消息
        //队列、自动确认
        channel.basicConsume("work", false, new DefaultConsumer(channel){
            //最后一个参数是从消息队列中取出的内容
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
                System.out.println("消费者-1：" + new String(body));
                //手动确认：确认队列中的哪个具体消息、是否开启多个消息同时确认
                channel.basicAck(envelope.getDeliveryTag(), false);
            }
        });
        //不关闭的话，consumer会一直监听
//        RabbitMQUtils.close(channel, connection);
    }
}
